package com.doit.sparksql.day01

import org.apache.spark.sql.DataFrame

/**
 * @DATE 2022/1/13/10:07
 * @Author MDK
 * @Version 2021.2.2
 * */
object SQL02_CSV {
  def main(args: Array[String]): Unit = {
    val spark = SQLUtil.getSession
    //加载没有头字段信息的表数据
    //创建数据的结构对象

    //自动推导数据类型 自动识别数据类型
    val df: DataFrame = spark
      .read
      .option("header", true)
      .option("inferSchema", true)
      .csv("sql_data/csv/a.csv")

    df.printSchema()
    df.createTempView("user")
    spark.sql("select * from user").show()

    spark.close()

  }
}
